package org.example;

import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;

import java.util.Arrays;
import java.util.List;

public class spark40 {
    public static void main(String[] args) {
//        创建spark的运行环境
        final JavaSparkContext jsc =new JavaSparkContext("local","spark");
        final List<Integer> nums = Arrays.asList(1,2,3,4,5,6);
//        新建分区
        final JavaRDD<Integer> rdd1 = jsc.parallelize(nums,4);
//        打印分区
        System.out.println(rdd1.partitions().size());
//        释放资源
        jsc.close();
    }
}
//object data1_core{
////    spark 运行环境
//  val spark=new SparkContext()
//        .master("local[*]" :String)
//        .appName("spark")
//        .getOrCreate()
//      val sc =spark.sparkContext
////        1.创建rdd
////        2.分析数据
//        }
